class RpcTransport(object):

  def is_open(self):
    pass

  def open(self):
    pass

  def close(self):
    pass

  def read(self, length):
    pass

  def read_all(self, length):
    buff = ''
    i = 0
    while i < length:
    	chunk = self.read(length - i)
    	if len(chunk) == 0:
    		raise EOFError()
    	buff += chunk
    	i += len(chunk)
    return buff

  def write(self, buf):
    pass

  def flush(self):
    pass

